package org.xi.maple.api

import org.apache.spark.sql.{Dataset, Row, SparkSession}

import scala.collection.mutable

trait MapleSource[T <: SourceConfig] extends MaplePlugin[T] {
  def getData(spark: SparkSession, argsMap: mutable.Map[String, String]): Dataset[Row]
}
